package zhongbo.java.air.config;

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.listener.PatternTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.data.redis.listener.Topic;
import zhongbo.java.air.listener.RedisSubscribeLogChanelListener;

@Configuration
@Slf4j
public class RedisListenerConfig {

    public static String FLIGHT_PATH_CHANEL = "flight_path_chanel";

    /**
     * 配置redis 监听容器
     */

    @Autowired
    public void configListener(RedisMessageListenerContainer listenerContainer,
                               RedisSubscribeLogChanelListener logChanelListener){
        Topic logTopic = new PatternTopic(FLIGHT_PATH_CHANEL);
        listenerContainer.addMessageListener(logChanelListener,logTopic);
    }

}
